package com.ruoyi.config;

public class RabbitMqConstant {

    /**
     * FANOUT类型的交换机：api发布与撤销
     */
    public static final String FANOUT_EXCHANGE_API = "fanout.exchange.api";

    /**
     * FANOUT类型的队列：api发布与撤销
     */
    public static final String FANOUT_API_QUEUE = "fanout.api.queue";

    /**
     * TOPIC类型的交换机：工作流
     */
    public static final String TOPIC_EXCHANGE_WORKFLOW = "topic.exchange.workflow";

    /**
     * TOPIC类型的队列：工作流
     */
    public static final String TOPIC_WORKFLOW_QUEUE = "topic.workflow.queue";

    /**
     * TOPIC类型的路由键：工作流 {}占位符替换
     */
    public static final String TOPIC_WORKFLOW_KEY = "topic.workflow.key.";

    //#需要在rabbitmq 管理器上绑定TOPIC_FILE_PROCESS_QUEUE 到 EXCHANGE_FILE_PROCESS
    //文件解析
    public static final String EXCHANGE_FILE_PROCESS = "fanout.exchange.file.process";
    public static final String TOPIC_FILE_PROCESS_QUEUE = "fanout.file.process.queue";

    public static final String EXCHANGE_GEOSERVE_PUBLISH = "fanout.exchange.geoserver";
    public static final String TOPIC_GEOSERVE_QUEUE = "fanout.geoserver.queue";


    public static final String EXCHANGE_FILE_CONVERTOR = "fanout.exchange.file.convertor";
    public static final String ROUTING_KEY_FILE_CONVERTOR = "fileConvertor";
    public static final String TOPIC_FILE_CONVERTOR = "fanout.subject.file.convertor.queue";

    public static final String EXCHANGE_FILE_CONVERTOR_FINISH = "fanout.exchange.file.convertorFinish";
    public static final String ROUTING_KEY_FILE_CONVERTOR_FINISH = "fileConvertorFinish";
    public static final String TOPIC_FILE_CONVERTOR_FINISH = "fanout.subject.file.convertorFinish.queue";

    //////////////////////////////////////////////////////
    public static final String EXCHANGE_IOT_DEVICE_ADD = "fanout.exchange.iot.addDevice";
    public static final String ROUTING_KEY_IOT_DEVICE_ADD = "iotAddDevice";
    public static final String TOPIC_IOT_DEVICE_ADD = "fanout.subject.iot.addDevice.queue";
}
